package com.udf.common;

import org.apache.flink.table.functions.ScalarFunction;

public class LowerCaseUDF extends ScalarFunction {
    public String eval(String input) {
        if (input == null) {
            return null;  // 处理空值
        }
        return input.toLowerCase();
    }
}